package cn.itcast.wanxinp2p.depository.message;

import cn.itcast.wanxinp2p.common.domain.DepositoryConsumerResponse;
import cn.itcast.wanxinp2p.depository.config.RocketMQTemplateExt;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 专门处理消息发送，用来给用户中心消息发送，也就是mq的生产者
 *
 * @projectName wanxinp2p
 * @Description 　　* @param
 * 　　* @return
 */
@Component
public class GatewayMessageProducer {

    @Value("${rocketmq.tp-gateway-destination-agent.topic}")
    private String TOPIC_NAME;
    @Value("${rocketmq.tp-gateway-notify-agent.tag}")
    private String TAG_NAME;

    @Autowired
    private RocketMQTemplateExt rocketMQTemplate;



    //消息发送方法
    public void personalRegister(DepositoryConsumerResponse response) {
        //RMQ 同步发送，异步发送，单向，顺序，事务消息
        // 业务评估：业务量不大，安全 （同步）
        // 消息主题和tag ： topic:tag
        String destination =TOPIC_NAME+":"+TAG_NAME;

        //传递消息  response
        rocketMQTemplate.convertAndSend(destination, response);


    }

}
